adbe8850f5e14dae21bb65e53586048b6bc3f2dd,cdap-app-templates/cdap-etl/cdap-data-pipeline/src/test/java/co/cask/cdap/datapipeline/DataPipelineTest.java,DataPipelineTest,testPipelineWithActions,#,105
Before Change
.addConnection("source", "sink")
.addConnection("action1", "action2")
.addConnection("action2", "source")
.addConnection("sink", "action3")
.build();
AppRequest<ETLBatchConfig> appRequest = new AppRequest<>(APP_ARTIFACT, etlConfig);
Id.Application appId = Id.Application.from(Id.Namespace.DEFAULT, "MyApp");
After Change
.addConnection(sourceName, sinkName)
.addConnection("action1", "action2")
.addConnection("action2", sourceName)
.addConnection(sinkName, "action3")
.setEngine(engine)
.build();
AppRequest<ETLBatchConfig> appRequest = new AppRequest<>(APP_ARTIFACT, etlConfig);